package com.example.mq.common;

/*
 * 使用一个函数式接口,表示收到消息后进行怎样处理
 * 此处是一个回调函数,不由程序员手动调用,在程序适当时机调用
 */

import com.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {
    //把消息推送给消费者
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
